commandExecutor.syncSubscription(future);
try {
while (true) {
if (tryAcquire()) {
return super.poll();
}
@Override
public V poll() {
Long currentTimeout = tryAcquire();
if (currentTimeout == null) {
return super.poll();
}